package com.stone.customer.console.trigger.impl;

import com.stone.customer.console.infra.constant.CustomerConsoleConstant;
import com.stone.customer.console.trigger.AbstractRedisSyncTrigger;
import com.stone.message.adapter.infra.publisher.MessagePublisher;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * 积分同步触发器
 *
 * @author Mr_wenpan@163.com 2021/07/15 17:49
 */
@Component
@Deprecated
public class RedisPointSyncTrigger extends AbstractRedisSyncTrigger {

    @Resource(name = "pointSyncThreadPool")
    ThreadPoolTaskExecutor threadPoolTaskExecutor;

    public RedisPointSyncTrigger(MessagePublisher messagePublisher) {
        super(messagePublisher);
    }

    @Override
    protected String queue() {
        return CustomerConsoleConstant.RedisQueueName.POINT_SYNC_QUEUE;
    }

    @Override
    protected ThreadPoolTaskExecutor threadPoolTaskExecutor() {
        return threadPoolTaskExecutor;
    }
}
